package cn.doitedu.demo2;

import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

public interface RuleCalculator {

    /**
     * 运算机初始化
     */
    public void init(RuntimeContext runtimeContext, String ruleParamJson ) throws IOException;


    /**
     * 数据运算
     */
    public void calc(UserEvent userEvent, Collector<Message> out) throws IOException;


}
